package com.atguigu.tingshu.album.listener;

import com.alibaba.otter.canal.protocol.CanalEntry;
import com.xpand.starter.canal.annotation.CanalEventListener;
import com.xpand.starter.canal.annotation.ListenPoint;
import lombok.extern.slf4j.Slf4j;

@CanalEventListener     //声明当前类是canal的事件监听器
@Slf4j
public class CanalClientListener {
    @ListenPoint(destination = "example",schema = "tingshu_album",table = "album_info",eventType = {CanalEntry.EventType.UPDATE,CanalEntry.EventType.DELETE})
    public void albumInfoListener(CanalEntry.EventType eventType,CanalEntry.RowData rowData){

    }
}
